ISequentialWorkQueue<T>
Assembly: ServiceStack.Redis.dll
View Source
Declaration
public interface ISequentialWorkQueue<T> : IDisposable where T : class
Methods
Enqueue(String, T)
Enqueue item in priority queue corresponding to workItemId identifier
View Source
Declaration
void Enqueue(string workItemId, T workItem)
Parameters
| Type | Name |
|---|---|
System.String | workItemId |
<T> | workItem |
PrepareNextWorkItem()
Prepare next work item id for dequeuing
View Source
Declaration
bool PrepareNextWorkItem()
Returns
System.Boolean
Dequeue(Int32)
Dequeue up to maxBatchSize items from queue corresponding to workItemId identifier.
Once this method is called, ServiceStack.Redis.Support.Queue.ISequentialWorkQueue%601.Dequeue(System.Int32) will not
return any items for workItemId until the dequeue lock returned is unlocked.
View Source
Declaration
ISequentialData<T> Dequeue(int maxBatchSize)
Returns
ServiceStack.Redis.Support.Queue.ISequentialData<T>
Parameters
| Type | Name |
|---|---|
System.Int32 | maxBatchSize |
Update(String, Int32, T)
Replace existing work item in workItemId queue
View Source
Declaration
void Update(string workItemId, int index, T newWorkItem)
Parameters
| Type | Name |
|---|---|
System.String | workItemId |
System.Int32 | index |
<T> | newWorkItem |
HarvestZombies()
View Source
Declaration
bool HarvestZombies()
Returns
System.Boolean